mod tests {
    use rust_my_tools::component::rocketmq::{consumer, producer};

    use tokio::runtime::Builder;
    fn cre_runtime() -> tokio::runtime::Runtime {
        // 创建一个 Tokio 运行时，配置线程池的大小
        Builder::new_multi_thread()
            .worker_threads(1) // 设置工作线程的数量
            .max_blocking_threads(16) // 设置阻塞任务的最大线程数
            .enable_all()
            .build()
            .unwrap()
    }

 

    #[test]
    pub fn test_send_demo(){
        
        let runtime = cre_runtime();
        runtime.block_on(async {
            producer::demo_send().await;
        })
    }

    #[test]
    pub fn test_receive_demo(){
        
        let runtime = cre_runtime();
        runtime.block_on(async {
            consumer::demo_receive().await;
        })
    }
}